google.golang.org/grpc/internal/transport.Stream.ctx (field)
35 uses
google.golang.org/grpc/internal/transport (current package)
handler_server.go#L386: s.ctx = peer.NewContext(ctx, pr)
handler_server.go#L388: s.ctx = sh.TagRPC(s.ctx, &stats.RPCTagInfo{FullMethodName: s.method})
handler_server.go#L394: sh.HandleRPC(s.ctx, inHeader)
handler_server.go#L397: reader: &recvBufferReader{ctx: s.ctx, ctxDone: s.ctx.Done(), recv: s.buf, freeBuffer: func(*bytes.Buffer) {}},
http2_client.go#L480: s.ctx = ctx
http2_client.go#L483: ctx: s.ctx,
http2_client.go#L484: ctxDone: s.ctx.Done(),
http2_client.go#L865: sh.HandleRPC(s.ctx, outHeader)
http2_client.go#L1190: if d, ok := s.ctx.Deadline(); ok && !d.After(time.Now()) {
http2_client.go#L1540: sh.HandleRPC(s.ctx, inHeader)
http2_client.go#L1547: sh.HandleRPC(s.ctx, inTrailer)
http2_server.go#L508: s.ctx, s.cancel = context.WithTimeout(t.ctx, timeout)
http2_server.go#L510: s.ctx, s.cancel = context.WithCancel(t.ctx)
http2_server.go#L515: s.ctx = metadata.NewIncomingContext(s.ctx, mdata)
http2_server.go#L517: s.ctx = stats.SetIncomingTags(s.ctx, []byte(statsTags[len(statsTags)-1]))
http2_server.go#L520: s.ctx = stats.SetIncomingTrace(s.ctx, []byte(statsTrace[len(statsTrace)-1]))
http2_server.go#L558: if s.ctx, err = t.inTapHandle(s.ctx, &tap.Info{FullMethodName: s.method}); err != nil {
http2_server.go#L589: s.ctx = traceCtx(s.ctx, s.method)
http2_server.go#L591: s.ctx = sh.TagRPC(s.ctx, &stats.RPCTagInfo{FullMethodName: s.method})
http2_server.go#L600: sh.HandleRPC(s.ctx, inHeader)
http2_server.go#L602: s.ctxDone = s.ctx.Done()
http2_server.go#L606: ctx: s.ctx,
http2_server.go#L954: return ContextErr(s.ctx.Err())
transport.go#L247: ctx context.Context // the associated context of the stream
transport.go#L329: case <-s.ctx.Done():
transport.go#L332: s.ct.CloseStream(s, ContextErr(s.ctx.Err()))
transport.go#L414: return s.ctx